import org.apache.spark.{SparkConf, SparkContext}

object scala4212 {
  def main(args: Array[String]): Unit = {
    // 创建Spark配置
    val conf = new SparkConf().setAppName("FilterExample").setMaster("local[*]")
    // 创建SparkContext
    val sc = new SparkContext(conf)

    // 创建RDD
    val rdd1 = sc.parallelize(List(('a', 1), ('b', 2), ('c', 3)))
    // 通过filter()方法过滤其中每个元组第二个值小于等于1的元素
    val filteredRDD = rdd1.filter(_._2 > 1)
    val result = filteredRDD.collect()
    result.foreach(println)

    // 关闭SparkContext
    sc.stop()
  }
}